package com.example.messagequeue.commom;

import com.example.messagequeue.mqserver.core.BasicProperties;

import java.io.IOException;

@FunctionalInterface
public interface Consumer {
    //Delivery的意思是投递，这个方法的预期是在每次服务器收到消息之后来调用的
    //通过这个方法把消息推送到对应的消费者
    void handleDelivery(String consumeTag, BasicProperties basicProperties, byte[] body) throws IOException, MqException;
}
